package com.jacarrichan.demo.springcloudstream.stream.source;

import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;

/**
 * 自定义消息数据source(其实就是管道的源头名称)
 * @author JacarriChan
 * @date 2019/7/27
 */
public interface MyMessageSource {

    /**
     * Name of the output channel.
     */
    String MSG_DEMO_NAME = "jacarrichan";

    /**
     * 自定义的输出
     * @return output channel
     */
    @Output(MyMessageSource.MSG_DEMO_NAME)
    MessageChannel demoOutput();
}
